46aa0b2c822fc19b6e1c2e4208d71d1acae6eeb9,enterprise/main/java/org/neo4j/kernel/ha/MasterImpl.java,MasterImpl,packResponse,#SlaveContext#T#Predicate#,337

Before Change


        try
        {
            TransactionStreams streams = new TransactionStreams();
            for ( Map.Entry<String, Long> slaveEntry :
                    context.lastAppliedTransactions().entrySet() )
            {
                String resourceName = slaveEntry.getKey();
                XaDataSource dataSource = getConfig().getTxModule()
                        .getXaDataSourceManager().getXaDataSource( resourceName );
                long masterLastTx = dataSource.getLastCommittedTxId();
                long slaveLastTx = slaveEntry.getValue();
                Collection<ReadableByteChannel> channels = new ArrayList<ReadableByteChannel>();
                for ( long txId = slaveLastTx+1; txId <= masterLastTx; txId++ )
                {
                    if ( filter.accept( txId ) )
                    {
                        channels.add( dataSource.getCommittedTransaction( txId ) );
                    }
                }
                streams.add( slaveEntry.getKey(), new TransactionStream( channels ) );
            }
            return new Response<T>( response, streams );
        }

After Change


        try
        {
            TransactionStreams streams = new TransactionStreams();
            for ( Pair<String, Long> txEntry : context.lastAppliedTransactions() )
            {
                String resourceName = txEntry.first();
                XaDataSource dataSource = graphDbConfig.getTxModule().getXaDataSourceManager()
                        .getXaDataSource( resourceName );
                long masterLastTx = dataSource.getLastCommittedTxId();
                Collection<ReadableByteChannel> channels = new ArrayList<ReadableByteChannel>();
                for ( long txId = txEntry.other()+1; txId <= masterLastTx; txId++ )
                {
                    if ( filter.accept( txId ) )
                    {